package com.angular.useradmin.user.listener;

import com.angular.useradmin.user.entity.Message;

import com.angular.useradmin.user.handler.CanalHandler;
import org.springframework.stereotype.Component;
import top.javatool.canal.client.annotation.CanalTable;
import top.javatool.canal.client.handler.EntryHandler;
@CanalTable("user_message")
@Component
public class CanalListener implements EntryHandler<Message> {
    private  final CanalHandler canalHandler;
    public CanalListener(CanalHandler canalHandler) {
        this.canalHandler = canalHandler;
    }
    /*
     * 数据库插入数据的处理
     */
    @Override
    public void insert(Message item) {
        canalHandler.insertHandler(item);
    }
    /**
     * 数据库更新数据的处理
     */
    @Override
    public void update(Message before, Message after) {
        canalHandler.update(before,after);

    }
    /**
     * 数据库删除数据的处理
     */
    @Override
    public void delete(Message item) {
       canalHandler.delete(item);
    }
}
